package com.dtwave.lnstreaming.process.selector;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.utils.JsonUtils;
import org.apache.flink.api.java.functions.KeySelector;

public class XfaceKeySelector implements KeySelector<JSONObject,String> {


    @Override
    public String getKey(JSONObject jsonObject) throws Exception {
        return JsonUtils.getString(jsonObject,true,"after");
    }
}
